153d71b52fb6e9507dbcff3aedbc05d1a7e150f8,rxnetty-examples/src/main/java/io/reactivex/netty/examples/http/loadbalancing/HttpLoadBalancingClient.java,HttpLoadBalancingClient,main,#String[]#,51
Before Change
public static void main(String[] args) {
/*Start 3 embedded servers, two healthy and one unhealthy to demo failure detection*/
final SocketAddress[] hosts = { startNewServer(OK), startNewServer(OK), startNewServer(SERVICE_UNAVAILABLE)};
/*Create a new client using the load balancer over the hosts above.*/
HttpClient.newClient(HttpLoadBalancer.create(hosts))
After Change
public static void main(String[] args) {
/*Start 3 embedded servers, two healthy and one unhealthy to demo failure detection*/
final Observable<SocketAddress> hosts = Observable.just(startNewServer(OK), startNewServer(OK),
startNewServer(SERVICE_UNAVAILABLE));
/*Create a new client using the load balancer over the hosts above.*/
HttpClient.newClient(HttpLoadBalancer.create(hosts))